Skip to content

PrioritySemaphoreSignal class

Defined in

Namespace: ReactiveUI.Primitives.Reactive.Signals Assembly: ReactiveUI.Primitives.Reactive.dll Full name: ReactiveUI.Primitives.Reactive.Signals.PrioritySemaphoreSignal<T> Modifiers: public sealed

Summary

View source

A signal that limits forwarded values with priority-based semaphore semantics.

Applies to

net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481

Class hierarchy
classDiagram
class PrioritySemaphoreSignal~T~
class ISignal~T~ {
    <>
}
ISignal~T~ <|.. PrioritySemaphoreSignal~T~
class ISignal~T, T~ {
    <>
}
ISignal~T, T~ <|.. PrioritySemaphoreSignal~T~
class IObserver~T~ {
    <>
}
IObserver~T~ <|.. PrioritySemaphoreSignal~T~
class IObservable~T~ {
    <>
}
IObservable~T~ <|.. PrioritySemaphoreSignal~T~
class IsDisposed {
    <>
}
IsDisposed <|.. PrioritySemaphoreSignal~T~
class IDisposable {
    <>
}
IDisposable <|.. PrioritySemaphoreSignal~T~

Implements: ISignal, ISignal, IObserver, IObservable, IsDisposed, IDisposable

Constructors

NameSummary
.ctorInitializes a new instance of the [PrioritySemaphoreSignal](# class.

Properties

NameSummary
HasObserversGets a value indicating whether this instance has observers.
IsDisposedGets a value indicating whether this instance is disposed.
MaximumCountGets or sets the maximum number of values allowed through before release is required.

Methods

NameSummary
OnNext
ReleaseReleases one semaphore slot and drains queued values when capacity is available.
OnCompleted
OnError
Subscribe
Dispose
Inherited members